package syschannel_connector

import (
	"go-iot-gateway/internal/channel"
	channel_define "go-iot-gateway/internal/channel/define"
)

// 系统通道
type SysChannel struct {
	ChannelInfo    channel_define.ChannelInfo
	isClosed       bool
	channelManager *channel.ChannelManager
	//readTagGroupByDevice map[string][]*conf_table_define.TagInfo //读点位 key: 设备 | val: 转发点
	//writeTagList         []*conf_table_define.TagInfo            //写点位
	//waterlineFlags       map[string]int64                        //发布数据的水位线,记录的是每个设备最后上传数据的时间
}

func (s *SysChannel) Open() {
	//TODO implement me
	//panic("implement me")
	s.ChannelInfo.SetStatus(channel_define.CONNECT_STATUS_CONNECTED, "连接成功")
}

func (s *SysChannel) Close() {
	//TODO implement me
	//panic("implement me")
}

func (s *SysChannel) Info() channel_define.ChannelInfo {
	//TODO implement me
	//panic("implement me")
	return s.ChannelInfo
}
